bc7d1d037031558d5d93ebdc85434803ac3ec53c,portal-impl/test/unit/com/liferay/portal/fabric/netty/repository/NettyRepositoryTest.java,NettyRepositoryTest,testGetFileTimeoutCancellation,#,685
Before Change
@Test
public void testGetFileTimeoutCancellation() {
NettyRepository repository = new NettyRepository(
_repositoryPath, _embeddedChannel, _embeddedChannel.eventLoop(), 0);
NoticeableFuture<Path> noticeableFuture = repository.getFile(
Paths.get("remoteFile"), Paths.get("localFile"), false, false);
After Change
@AdviseWith(adviceClasses = NettyUtilAdvice.class)
@Test
public void testGetFileTimeoutCancellation() {
AsyncBroker<Path, FileResponse> asyncBroker =
new AsyncBroker<Path, FileResponse>();
_channelPipeline.addLast(
new FileResponseChannelHandler(
asyncBroker, _embeddedChannel.eventLoop()));
NettyRepository repository = new NettyRepository(
_repositoryPath, asyncBroker, 0);